package cn.com.idmy.mq.annotation;

import cn.com.idmy.mq.coder.MqMsgDecoder;

import java.lang.annotation.*;

@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface MqSubscribe {
    String[] value() default {"*"};

    String topic() default "";

    Class<? extends MqMsgDecoder>[] decoder() default {};
}
